package com.pengheng.service.impl;

import com.pengheng.bean.WaterSensor;
import com.pengheng.service.ITrafficIndicatorAlgorithm;
import org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator;

/**
 * 停车次数和停车时间指标计算
 */
public class StopCountParkTimeTrafficIndicatorAlgorithm implements ITrafficIndicatorAlgorithm {


    @Override
    public void algorithm(SingleOutputStreamOperator<WaterSensor> singleOutputStreamOperator) throws Exception {
        System.out.println("停车计算逻辑");
    }
}
